package com.seventeen.monster.web.delayed;

import com.seventeen.monster.redisson.annotation.DelayedQueueListener;
import com.seventeen.monster.redisson.core.DelayedQueueHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@DelayedQueueListener(queueName = "test", consumeThreadNumber = 4, retryLevelWhenNextConsume = 1)
public class TestDelayedQueueListener implements DelayedQueueHandler<String> {

    private final static Logger log = LoggerFactory.getLogger(TestDelayedQueueListener.class);

    @Override
    public void onMessage(String message) {
        log.info("redisson delay queue message {}", message);
//        int i = 1/0;
    }
}
